package com.ok.constant;

import com.alibaba.fastjson.JSONObject;

import java.util.concurrent.ArrayBlockingQueue;

/**
 * 全局业务队列
 */
public class JmQueue {
    //插入iotdb队列
    public static final ArrayBlockingQueue<JSONObject> insertIotdbBQ = new ArrayBlockingQueue<>(10000 * 10 * 5);
    //实时值变动队列
    public static final ArrayBlockingQueue<JSONObject> pointRDataChangeBQ = new ArrayBlockingQueue<>(10000 * 2);
    //实时值队列
    public static final ArrayBlockingQueue<JSONObject> pointRDataBQ = new ArrayBlockingQueue<>(10000 * 2);

}
